import { Injectable } from "@nestjs/common";
import { InjectRepository } from "@nestjs/typeorm";
// 连接数据库 中的表
import { Repository } from 'typeorm'
import { jy_data, summary } from 'src/entities/Wealth.entity'
const colorsjs = require('colors');
// 引入 websocket
import { WsGateway } from '../ws/ws.gateway'

/* 处理 jy_data */
@Injectable()
export class WealthService_jyData {
  constructor(
    @InjectRepository( jy_data )
    private readonly jyDataRepository: Repository<jy_data>,
    @InjectRepository( summary )
    private readonly jyDataSummary: Repository<summary>
  ){}
  // 
  async get_jyData():Promise<any> {
    const jyData = await this.jyDataRepository.find()
    // console.log('jyDataRepository', jyData)
    return jyData
  }
  // 先 jy_data表中保存数据
  async setMore_wealth_jyData(jyData: any = {positions:[]}): Promise<string> {
    // console.group('<--- setMore_wealth_jyData --->')
    // console.log('需要保存的全部 jyData 的数据', jyData[0].Dryk, jyData[0].positions)
    // console.log('<--- setMore_wealth_jyData --->'.green)
    // colorsjs.green('<--- setMore_wealth_jyData --->')

    // 钱列表
    let money = '';
    const jy_data = [];
    // 汇总
    const summaryTotal = {};
    jyData.forEach(item => {
      // console.log( 'item', item )
      item.positions.forEach(list => {
        jy_data.push({...list, NOEDATE: new Date()})
        money += ' '+list.Zqmc+'-- *'+list.Dryk+' '
      });
    });
    // 全部数据
    await this.jyDataRepository.save( jy_data )
    // 汇总数据
    await this.jyDataSummary.save({
      date: new Date().toLocaleString(),
      drhz: jyData[0].Dryk,
      num: jyData[0].positions.length,
      zsz: jyData[0].Zzc,
      ccyk: jyData[0].Ljyk,
      stocks: JSON.stringify(jyData[0].positions)
    })
    // 显示当天的盈亏
    console.log('日期时间 --->', new Date().toLocaleString().red)
    console.log("当日盈亏 --->", jyData[0].Dryk > 0 ? jyData[0].Dryk.red : jyData[0].Dryk.green)
    console.log('字符串列表 --->', colorsjs.rainbow(money))
    // console.groupEnd()
    return jyData[0].Dryk + ' 数据保存成功 !!!'
  }
}
